package server

import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.ipc.RPC
import protocol.Info
import protocol.impl.StudentInfo

object Server {

  def main(args: Array[String]): Unit = {
    val server = new RPC.Builder(new Configuration())
      // 指定协议接口类
      .setProtocol(classOf[Info])
      // 指定协议接口实现类
      .setInstance(new StudentInfo)
      // 指定监听地址为本地 ip
      .setBindAddress("0.0.0.0")
      // 指定监听端口
      .setPort(65530)
      .build()
    server.start()
  }
}
